package com.openlogic.datasource.api.event;

import org.noear.solon.cloud.CloudClient;
import org.noear.solon.cloud.model.Event;

import com.alibaba.fastjson2.JSONObject;

/**
* @ClassName: DataDeleteEvent
* @Description: 删除元数据事件
* @author weiyongpeng
* @date 2024年11月18日 上午9:04:26
 */
public class DataDeleteEvent {

	/**
	* 描述：缓存数据源事件
	* @Title: publishDeleteEvent
	* @param dataDeleteEventModel
	* @author weiyongpeng
	 * @return 
	* @date  2024年11月10日 下午6:02:50
	 */
	public boolean publishDeleteEvent(DataDeleteEventModel dataDeleteEventModel) {
		// 这里使用的是eventplus分布式事件扩展包，需要配合Solon Cloud Event插件使用，这里使用rabbitmq作为事件处理器组件
		Event event = new Event("data.delete.event",JSONObject.toJSONString(dataDeleteEventModel)).group("delete");
		return CloudClient.event().publish(event);
	}
}
